package com.etl.process.execute;

/**
 * 执行阶段线程池
 */
public class ExecutePool {
    /**
     *  每一段任务是 10000条数据
     *  使用visualvm工具可以检测程序中 可以通过其他工具来检测处理1w条数据大概需多少内存
     *  然后根据 程序CPU 内存 进行 计算 开多少线程核实
     *  会得到个结果 这个结果 * 80% 就是这个程序的 阈值 达到阈值再启动就会宕机
     *  没ID阿UN任务 1w条 职能跑30条任务段 要做80%的阈值
     *      实际只能跑 24 个
     *      但程序最开始初始化的时候 数量是 30%
     *      30*30% = 9 个  程序最开始默认启动30%
     *  需要给这个系统 schedule 系统 发送 9 个消息 IP + 端口号的消息
     *  程序运行了一段时间 接收到了9个消息 并且一直在处理 扩容按照 floor( 9 * 1.5) = 13
     *     13 - 9 = 4
     *     再给schedule 系统 发消息 发送4个IP+端口号的消息
     *
     *
     *  任务组完成后需要给系统发送回制消息 确认任务执行完成
     *  schedule系统把 ‘我’ 放入空闲队列当中
     *
     *  这时候有任务来了 会分配给 ‘我’ 这个队列  这个时候构造一个归还
     *
     *  用来注册给 负责实例注册 RegExecuteIns
     *
     *
     *
     */
}
